# ！/usr/bin/env python
# _*_ coding utf-8 _*_
# 由于IO操作非常耗时，程序经常会处于等待状态
# 比如请求多个网页有时候需要等待，gevent可以自动切换协程
# 遇到阻塞自动切换协程，程序启动时执行monkey.patch_all()解决
# 多个协程，可以采用pool管理并发数，限制并发任务数
# 首行添加下面语句即可
from gevent.pool import Pool
import gevent
from urllib import request
from gevent import monkey
monkey.patch_all()


def run_task(url):
    print('visit --> %s' % url)
    try:
        response = request.urlopen(url)
        data = response.read()
        print("%d bytes received from %s." % (len(data), url))
    except Exception:
        print("error")


if __name__ == '__main__':
    urls = ['https://github.com',
            'https://blog.csdn.net', 'https://bbs.csdn.net']
    greenlets = [gevent.spawn(run_task, url) for url in urls]
    gevent.joinall(greenlets)
# 运行结果可以发现，三个协程同时触发，但是结束顺序不同
# 网页请求的时间不同，故结束顺序不同
# 该程序只有一个线程

# 多个协程，可以采用pool管理并发数，限制并发任务数
if __name__ == '__main__':
    # 指定协程同时执行的数量
    pool = Pool(2)
    urls = ['https://github.com',
            'https://blog.csdn.net', 'https://bbs.csdn.net']
    pool.map(run_task, urls)
# 运行结果可以发现，先访问两个网址
# 第一个协程执行完毕之后，开始第三个协程
